草庐IT

Hadoop MapReduce 输出

全部标签

go - 给定一个任意字符串,我怎样才能将命令输出到 bash?

我有一个非常基本的golang问题。给定一个任意字符串,例如"echofoo"或"CGO_ENABLED=0gobuild-o./bin/echo-amain.go",什么是使用os/exec解析/运行该命令的惯用方法?我完成这项工作的方式似乎很老套,我正在寻找一种更惯用的方法。userInput="CGO_ENABLED=0gobuild-o./bin/echo-amain.go"command:=exec.Command("/bin/bash","-c",userInput)out,err:=command.Output()iferr!=nil{fmt.Println(err)}

multithreading - 为什么这个 go 代码输出这样?

我在here学习Go语言,我修改了一些这样的代码,我在quit之前添加了一个sleep(2s),并输出斐波那契数的索引i,下面是我的代码:packagemainimport"fmt"import"time"funcfibonacci(c,quitchanint){x,y:=0,1for{select{casec我发现标准输出立即输出0-8,但等待2秒它输出第9,然后“退出”。我将这段代码移动到一个单独的go文件中并运行它。起初它像上面描述的那样输出0-8,但是在我多次更改总数(从10到9,8或3,等等)之后,它立即直接输出所有斐波那契数,因为我被排除在外(当然它在之后输出quit2秒)

curl - 如何接受来自 Go 的 POST 请求并将输出写入文件?

首先,我尝试在Go中创建一个日志记录服务,它是一个轻量级服务器,它接受带有来self的服务的日志数据的POST请求。我正在用Go编写此服务,因为它应该很快并且可以同时处理大量POST请求。我的逻辑是否正确?无论如何,这是我的问题。我正在发送这样的POST请求来测试:curl-H"Content-Type:application/json"-XPOST-d'{"hello":"world"}'http://localhost:8080/log到目前为止,这是我的Go脚本:packagemainimport("fmt""log""net/http")funclogger(whttp.Res

go - 从 golang 或 core.async 中的输出 channel 批处理项目

我有一个将数据从kafka索引到elasticsearch的用例。Elasticsearch有一个批量API,它将多条消息捆绑在一个API调用中以进行索引。这比对每条消息逐条索引要高效得多。我正在使用Clojure来执行此操作。自然地,我想使用core.async,使用来自kafka的消息并输入到channel中,缓冲一段时间或当channel有足够的消息时,然后在一个elasticsearch批量API调用中为它们建立索引。问题是只要有一条消息传入,channel的输出就会发出信号。一个简单的解决方案是在阻塞队列中缓冲来自channel输出的传入消息,但这听起来似乎违背了使用chan

go - 在 Go 中编写一个打包的二进制文件的惯用方法是什么,它会产生与这个 Python 相同的输出?

我正在尝试找出如何在Go中编写与以下Python相对应的二进制文件的最佳方法:importstructf=open('tst.bin','wb')fmt='iih'f.write(struct.pack(fmt,4,185765,1020))f.close()我一直在修改我在Github.com和其他一些来源上看到的一些例子但我似乎无法让任何东西正常工作。在Go中执行此类操作的惯用方法是什么?下面是我现在是如何完成的(Golang):packagemainimport("fmt""os""encoding/binary")funcmain(){fp,err:=os.Create("ts

go - 无法测试 Golang CLI 工具的输出

我有一个用Go编写的cli工具,它产生以下输出:Command:configgetEnv:intComponent:foo-componentUnabletofindanyconfigurationwithinCosmos(http://api.foo.com)forfoo-component.我想在测试中验证这个输出。我写的(没通过)测试如下:packagecommandimport("testing""github.com/my/package/foo")typeFakeCliContextstruct{}func(sFakeCliContext)String(namestring

go - unicode 按字面输出而不是 unicode

我正在使用Go创建一个IRC机器人作为第一个项目来掌握这门语言。机器人功能之一是从TVmazeAPI中获取数据并显示在channel中。我导入了一个env包,它允许机器人管理员定义输出的显示方式。例如SHOWSTRING="#showname#-#status#–#network.name#"我正在尝试为其添加功能,以便管理员可以使用IRC格式化功能,该功能通过\u0002访问,例如,这是粗体\u0002。我有一个函数可以生成要返回并显示在channel中的字符串。funcgenerateString(showShow)string{str:=os.Getenv("SHOWSTRING

go - 将字符串与嵌套映射连接时无法获得适当的输出

我是galang的新手,我想用嵌套映射连接字符串。下面是给出的伪代码,指出我的错误。提前致谢import("fmt""strconv")funcmain(){str:="Hello@Johnmartin#sosos&Hi@William"varkeystring=""varkuint=0varkhint=0varkgint=0varidstringvarcolstringvarretMap=make(map[string]map[string]string)retMap[key]=make(map[string]string)fori:=0;i>",str[i])ifstr[i]==6

go - 从 exec.Command 输出解析整数

我目前正在尝试从我的Go程序中运行一个命令,并从响应中解析一个整数。该命令返回如下输出:6fyb_src/ex1.fyb(1)wins!使用strings.Split和strings.TrimSpaces拆分行并删除空格效果很好。但是,在尝试将数字解析为整数时出现以下错误:panic:strconv.ParseInt:parsing"0\r1\r2\r3\r4\r5\r6":invalidsyntax但是将我尝试解析的字符串打印到终端会产生以下结果:6我不太确定从这里到哪里去。这个数字对我来说显然像一个整数。错误消息也没有用(至少对我而言)。有人有想法吗?编辑:我正在运行的代码out,

testing - 去测试特定的文件输出

我是Go的新手,正在尝试从事一个项目。代码结构如下handlers/-time.go-time_test.go我已经试过gobuild,make(project)name问题是,我想在代码中添加一些控制台输出,以便我知道分支是否被覆盖(或用于调试)。现在,它对我不起作用。如果我使用:gotest-runtest_file_path如果只是输出Pass0.009s甚至我将t.Log("printlog")甚至fmt.Print("SayHello")放在测试函数中。如果我只使用gotest-vtest_file_path我会有undefinedvariable。构建和测试将失败。有什么建